50b490e046bdc23b23fbb268400abcc41a0de72c,src/java/org/apache/cassandra/service/ReadCallback.java,ReadCallback,response,#Message#,129

Before Change



    public void response(Message message)
    {
        resolver.preprocess(message);
        int n = waitingFor(message)
              ? received.incrementAndGet()
              : received.get();

After Change


        return blockfor == 1 ? resolver.getData() : resolver.resolve();
    }

    public void response(Message message)
    {
        ReadResponse result = resolver.preprocess(message);
        int n = waitingFor(result, message.getFrom())
              ? received.incrementAndGet()
              : received.get();